//package com.itheima.redis_queue;
//
//import java.util.concurrent.TimeUnit;
//
//import org.redisson.api.RBlockingQueue;
//import org.redisson.api.RDelayedQueue;
//import org.redisson.api.RedissonClient;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//import lombok.extern.slf4j.Slf4j;
//
///**
// * @author  ：yuan_he_song
// * @date  ： 2020/9/29
// * @description：redis延迟队列
// */
//@Component
//@Slf4j
//public class RedisDelayedQueue {
//
//    @Autowired
//    RedissonClient redissonClient;
//
//    /**
//     * 添加队列
//     * @param body 消息体
//     * @param delay 时间数量
//     * @param timeUnit 时间单位
//     * @param <T>
//     */
//    public <T> void sendDelayMsg(T body, long delay, TimeUnit timeUnit, String name) {
//        RBlockingQueue<T> blockingFairQueue = redissonClient.getBlockingQueue(name);
//        RDelayedQueue<T> delayedQueue = redissonClient.getDelayedQueue(blockingFairQueue);
//        delayedQueue.offer(body, delay, timeUnit);
//        delayedQueue.destroy();
//    }
//
//}
